dc720bd68cbdcb5b853a1c5b1876e0e9288dd6e9,integration/mesos/src/main/java/alluxio/mesos/AlluxioScheduler.java,AlluxioScheduler,resourceOffers,#SchedulerDriver#List#,110
Before Change
Protos.Environment.Variable.newBuilder()
.setName("ALLUXIO_LOGS_DIR").setValue("logs")
.build())
.addVariables(
Protos.Environment.Variable.newBuilder()
.setName("ALLUXIO_WORKER_MEMORY_SIZE").setValue(memSize)
.build())
.addVariables(
Protos.Environment.Variable.newBuilder()
.setName("ALLUXIO_UNDERFS_ADDRESS")
.setValue(Configuration.get(PropertyKey.UNDERFS_ADDRESS))
.build())
.addVariables(
Protos.Environment.Variable.newBuilder()
.setName("ALLUXIO_MESOS_SITE_PROPERTIES_CONTENT")
.setValue(createAlluxioSiteProperties())
.build())
.build()));
// pre-build resource list here, then use it to build Protos.Task later.
resources = getWorkerRequiredResources(workerCpu, workerMem);
After Change
.setName("ALLUXIO_UNDERFS_ADDRESS")
.setValue(Configuration.get(PropertyKey.UNDERFS_ADDRESS))
.build())
.addVariables(
Protos.Environment.Variable.newBuilder()
.setName("ALLUXIO_MESOS_SITE_PROPERTIES_CONTENT")
.setValue(createAlluxioSiteProperties())
.build())
.build()));
// pre-build resource list here, then use it to build Protos.Task later.
resources = getWorkerRequiredResources(workerCpu, workerMem);
mWorkers.add(offer.getHostname());